package com.zxjbyte.yiyi.extension.sse.service;

import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

/**
 * @Author zhangxingjia
 * @Date 2024/6/24 17:50
 * @Version: 1.0
 */
public interface SseEmitterService {

    SseEmitter createConnect(String clientId, Boolean openHeartBeat);

    void closeConnect(String clientId);

    void broadcast(String clientId, String message);

    void sendOne(String clientId, String message);
}
